//package com.itcast.mongo;
//
//import java.io.File;
//import java.io.IOException;
//import java.util.List;
//import java.util.Map;
//import java.util.UUID;
//
//import org.apache.commons.io.FileUtils;
//
//import com.itcast.util.JsonUtils;
//import com.mongodb.DB;
//import com.mongodb.DBCollection;
//import com.mongodb.DBCursor;
//import com.mongodb.Mongo;
//
//
//
//public class Mongodb {
//
//	public static void main(String[] args) throws IOException {
//		Mongo mongo = new Mongo("192.168.0.160",27017);
//	        DB db = mongo.getDB("iris");
//	        System.out.println(db);
//	        System.out.println(db.getCollection("task"));
//	        DBCollection dbCollection = db.getCollection("data_1234");
//	        System.out.println(dbCollection.count());
//	        DBCursor dbCursor =   dbCollection.find();
//	      //  String s = "\""+"标讯链接\",\""+"正文\"";
//	        //采集日期、标讯链接、主页链接、关键词、正文
//            StringBuffer str3 = new StringBuffer();//关键字
//	        while(dbCursor.hasNext()){
//	        	 File file = new File("c:/Users/"+"xiaozhanghe"+"/", UUID.randomUUID()+".html");
//	        	String ss = dbCursor.next().toString();
//	            Map<String, Object> map = JsonUtils.toMap(ss);
//	            //System.out.println(ss);
//	            //判断里面有木有如果有的话就写数据进去
//	            boolean flag = true;
//	            List<String> list = Cont.getList();
////	            str3.append("\"");
////	        	for(int i=0;i<list.size();i++){//循环关键词列表
////        			String mapString = map.get("content_all").toString();//获取到正文的字符串形式
////					if(mapString.contains(list.get(i))){//判断是否能匹配到数据
////						flag = true;
//////						for(int m=0;m<list.size();m++){
////						str3.append(list.get(i));
////						str3.append(",");
////						System.out.println(list.get(i));
//////						}
////					}
////	        		
////	        	}
//	        	//str3.append("\",");
//	            try {
//	            	   if(flag){//如果存在
//	   	            	StringBuffer str = new StringBuffer();
//	   	            	str.append(map.get("ind").toString());
//	   	            	str.append("\r\n");
//	   	            	str.append(map.get("orgUrl").toString());
//	   	            	str.append("\r\n");
//	   	            	str.append(DataClean.clean(map.get("column1").toString()));
//	   	            	str.append("\r\n");
//	   	            	str.append("\r\n");
//	   	            	str.append(System.currentTimeMillis());
//	   	            	str.append("\r\n");
//	   	            	str.append(map.get("content_all").toString());
//	   					FileUtils.write(file, str.toString(), "UTF-8", true);
//	   					//FileUtils.write(file, "\r\n", "GBK", true);
//	   	            }else{
//	   	            	str3 = new StringBuffer();
//	   	            }
//	   	            str3 = new StringBuffer();
//				} catch (Exception e) {
//					e.printStackTrace();
//				}
//	         
//	       }  
//	}
//
//}
//
